package com.sjk.flink.pojo;

import lombok.Data;

import java.util.Date;

/**
 * 共通错误
 *
 */
@Data
public class ECTTY {

    /** topic名称 **/
    private String topicmc;

    /** 城市 **/
    private String cs;

    /** 原始数据 **/
    private String scrData;

    /** 操作时间 **/
    private String operate_time;

    /** 错误信息 **/
    private String errorMessage;

    /** 错误代码 **/
    private String errorCode;

    //城市
    private int city_partition_id;

    //城市
    private long city_offset_id;

    //城市
    private String city_ts;

    //集合层
    private int clayer_partition;

    //集合层
    private long clayer_offset;

    //集合层
    private String clayer_ts;

}
